from airflow.patsnap.service import workflow_service
from airflow.utils import dates

exe_date = dates.sh_now()
workflow_service.create_dag_run('dag-9', exe_date)

